package com.caption.mq.core;

import com.caption.mq.entity.MqSubscribeDO;

public interface MqConsumerManger {
    void startConsumer(AbstractMqConsumer consumer);

    AbstractMqConsumer createConsumer(MqSubscribeDO mqSubscribeDO);

    void stopConsumer(MqSubscribeDO mqSubscribeDO);

    void stopAllConsumer();
}
